package cn.baker.delayqueue.service;

/**
 * 延迟队列执行器
 *
 * @author yuanyu
 */
public interface RedisDelayQueueHandle<T> {

    /**
     * 返回队列编码
     *
     * @return
     */
    String queueCode();

    /**
     *
     * @return
     */
    Class<T> getDtoClass();

    /**
     * 收到延迟消息回掉
     *
     * @param jsonValue 数据
     */
    void execute(T jsonValue);

}